/**
 * Copyright (C) 2008-2010 Matt Gumbley, DevZendo.org <http://devzendo.org>
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *         http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.devzendo.minimiser.util;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/**
 * Manages a pool of worker threads.
 * 
 * @author matt
 *
 */
public final class WorkerPool {
    private ExecutorService executorService;

    /**
     * Construct a WorkerPool
     */
    public WorkerPool() {
        executorService = Executors.newCachedThreadPool();
    }

    /**
     * Submit a task for execution
     * @param task the Runnable to execute.
     */
    public void submit(final Runnable task) {
        executorService.submit(task);
    }
    
    /**
     * Submit a task for execution, obtaining a Future to obtain its completion.
     * @param <T> the type that this Callable will return upon completion
     * @param task the task
     * @return a Future<T> that can be polled, or .get().
     */
    public <T> Future<T> submit(final Callable<T> task) {
        return executorService.submit(task);
    }
}
